# 客户端/生产者
# 为了读取配置文件，需要提前配置环境
import os
# 1）实例化对象；
from celery import Celery

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings.dev")

celery_app = Celery('meiduo')
# 2）加载配置（指定中间人/消息队列/仓库）；
celery_app.config_from_object('celery_tasks.config')
# 3）制定celery可以生成任务；此处无需写到tasks，该名字固定，无需写，系统自动识别；
celery_app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.email'])